type golang.org/x/net/http2.clientStream
29 uses
golang.org/x/net/http2 (current package)
transport.go#L340: streams map[uint32]*clientStream // client-initiated
transport.go#L395: type clientStream struct {
transport.go#L448: func (cs *clientStream) get1xxTraceFunc() func(int, textproto.MIMEHeader) error {
transport.go#L455: func (cs *clientStream) abortStream(err error) {
transport.go#L461: func (cs *clientStream) abortStreamLocked(err error) {
transport.go#L476: func (cs *clientStream) abortRequestBodyWrite() {
transport.go#L486: func (cs *clientStream) closeReqBodyLocked() {
transport.go#L788: streams: make(map[uint32]*clientStream),
transport.go#L1267: func (cc *ClientConn) roundTrip(req *http.Request, streamf func(*clientStream)) (*http.Response, error) {
transport.go#L1269: cs := &clientStream{
transport.go#L1325: cancelRequest := func(cs *clientStream, err error) error {
transport.go#L1378: func (cs *clientStream) doRequest(req *http.Request, streamf func(*clientStream)) {
transport.go#L1392: func (cs *clientStream) writeRequest(req *http.Request, streamf func(*clientStream)) (err error) {
transport.go#L1536: func (cs *clientStream) encodeAndWriteHeaders(req *http.Request) error {
transport.go#L1596: func (cs *clientStream) cleanupWriteRequest(err error) {
transport.go#L1697: func (cc *ClientConn) awaitOpenSlotForStreamLocked(cs *clientStream) error {
transport.go#L1765: func (cs *clientStream) frameScratchBufferLen(maxFrameSize int) int {
transport.go#L1806: func (cs *clientStream) writeRequestBody(req *http.Request) (err error) {
transport.go#L1942: func (cs *clientStream) awaitFlowControl(maxBytes int) (taken int32, err error) {
transport.go#L2024: func (cc *ClientConn) addStreamLocked(cs *clientStream) {
transport.go#L2328: func (rl *clientConnReadLoop) handleResponse(cs *clientStream, f *MetaHeadersFrame) (*http.Response, error) {
transport.go#L2466: func (rl *clientConnReadLoop) processTrailers(cs *clientStream, f *MetaHeadersFrame) error {
transport.go#L2497: cs *clientStream
transport.go#L2708: func (rl *clientConnReadLoop) endStream(cs *clientStream) {
transport.go#L2724: func (rl *clientConnReadLoop) endStreamError(cs *clientStream, err error) {
transport.go#L2737: func (rl *clientConnReadLoop) streamByID(id uint32, headerOrData bool) *clientStream {
transport.go#L2752: func (cs *clientStream) copyTrailers() {